package com.atguigu.juc;

import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CopyOnWriteArraySet;

/**
 * 题目:请举例说明集合类是不安全的
 *
 *  1、故障现象
 *      java.util.ConcurrentModificationException
 *
 *  2、导致原因
 *
 *  3、解决方案
 *      3.1     Vector  不建议使用
 *      3.2     Collections.synchronizedXXX( new XXX<>());  不建议使用
 *      3.3     CopyOnWriteXXX<>();   JUC提供的
 *  4、优化建议(同样的错误，不出现第二次)
 *
 *  笔记
 *  写时复制
 *  CopyOnWrite容器即写实复制的容器，往一个容器添加元素的时候，不直接往当前容器Object[]添加，而是先将当前容器Object[]进行copy
 *  复制出一个新的容器Object[] newElements,然后新的容器Object[] newElements 里添加元素，添加元素之后
 *  再将原容器的引用指向新的容器，setArray(newElements);这样做的好处是可以对CopyOnWrite容器进行并发的读。
 *  而不需要加锁，因为当前容器不会添加任何元素，所有CopyOnWrite容器也是一种读写分离的思想。读和写不同容器。
 *
 *  HashSet底层是HashMap
 *
 *
 */
public class NoSafeDemo {

    public static void main(String[] args) {
    }

    public static void mapSafe() {
        Map<String,String > map = new ConcurrentHashMap<>();
        for (int i = 0; i < 30; i++) {
            new Thread(() -> {
                map.put(Thread.currentThread().getName(), UUID.randomUUID().toString().substring(0, 8));
                System.out.println(map);
            }, String.valueOf(i)).start();
        }
    }

    public static void setSafe() {
        Set<String> set = new CopyOnWriteArraySet<>();

        new HashSet<>();

        for (int i = 0; i < 30; i++) {
            new Thread(() -> {
                set.add(UUID.randomUUID().toString().substring(0, 8));
                System.out.println(set);
            }, String.valueOf(i)).start();
        }
    }

    public static void listSafe(){
        List<String> list = new CopyOnWriteArrayList<>();

        for(int i=0; i<30; i++){
            new Thread(()->{
                list.add(UUID.randomUUID().toString().substring(0,8));
                System.out.println(list);
            },String.valueOf(i)).start();
        }
    }

    public static void mapNoSafe() {
        Map<String,String > map = new HashMap<>();
        for (int i = 0; i < 30; i++) {
            new Thread(() -> {
                map.put(Thread.currentThread().getName(), UUID.randomUUID().toString().substring(0, 8));
                System.out.println(map);
            }, String.valueOf(i)).start();
        }
    }
}